Node / meshtastic / Meshtastic-Android / files / core / service / src / commonMain / kotlin / org / meshtastic / core / service / MessagingControllerImpl.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.service

Tff7b72import T7ee787co.touchlab.kermit.Logger

Tff7b72import T7ee787okio.ByteString

Tff7b72import T7ee787okio.ByteString.Companion.toByteString

Tff7b72import T7ee787org.meshtastic.core.common.util.nowMillis

Tff7b72import T7ee787org.meshtastic.core.common.util.safeCatching

Tff7b72import T7ee787org.meshtastic.core.model.ContactKey

Tff7b72import T7ee787org.meshtastic.core.model.DataPacket

Tff7b72import T7ee787org.meshtastic.core.model.MessageStatus

Tff7b72import T7ee787org.meshtastic.core.model.NodeAddress

Tff7b72import T7ee787org.meshtastic.core.model.Reaction

Tff7b72import T7ee787org.meshtastic.core.repository.CommandSender

Tff7b72import T7ee787org.meshtastic.core.repository.DataPair

Tff7b72import T7ee787org.meshtastic.core.repository.MeshDataHandler

Tff7b72import T7ee787org.meshtastic.core.repository.MessagingController

Tff7b72import T7ee787org.meshtastic.core.repository.NodeManager

Tff7b72import T7ee787org.meshtastic.core.repository.NodeRepository

Tff7b72import T7ee787org.meshtastic.core.repository.PacketRepository

Tff7b72import T7ee787org.meshtastic.core.repository.PlatformAnalytics

Tff7b72import T7ee787org.meshtastic.proto.AdminMessage

Tff7b72import T7ee787org.meshtastic.proto.PortNum

Tff7b72import T7ee787org.meshtastic.proto.SharedContact

Tff7b72import T7ee787org.meshtastic.proto.User

T8b949e/**

* [MessagingController] implementation: sends data packets, reactions, and shared contacts.

*

* Focused collaborator of [RadioControllerImpl]. Mirrors the SDK's `RadioClient.send*` surface — when the SDK is

* adopted this becomes a thin adapter over `RadioClient`.

*/

Tff7b72internal Tff7b72class T56d364MessagingControllerImplTb4b4b4(

Tff7b72private Tff7b72val Te6edf3commandSenderTb4b4b4: Te6edf3CommandSenderTb4b4b4,

Tff7b72private Tff7b72val Te6edf3nodeManagerTb4b4b4: Te6edf3NodeManagerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3nodeRepositoryTb4b4b4: Te6edf3NodeRepositoryTb4b4b4,

Tff7b72private Tff7b72val Te6edf3dataHandlerTb4b4b4: Te6edf3LazyTff7b72<Te6edf3MeshDataHandlerTff7b72>Tb4b4b4,

Tff7b72private Tff7b72val Te6edf3analyticsTb4b4b4: Te6edf3PlatformAnalyticsTb4b4b4,

Tff7b72private Tff7b72val Te6edf3packetRepositoryTb4b4b4: Te6edf3LazyTff7b72<Te6edf3PacketRepositoryTff7b72>Tb4b4b4,

Tb4b4b4) Tb4b4b4: Te6edf3MessagingController Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3myNodeNumTb4b4b4: Tffa657Int

Tff7b72getTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4.Te6edf3value Tff7b72?: T79c0ff0

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsendMessageTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3DataPacketTb4b4b4) Tb4b4b4{

Te6edf3commandSenderTb4b4b4.Te6edf3sendDataTb4b4b4(Te6edf3packetTb4b4b4)

Te6edf3dataHandlerTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3rememberDataPacketTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4, Tff7b72falseTb4b4b4)

Tff7b72val Te6edf3bytes Tff7b72= Te6edf3packetTb4b4b4.Te6edf3bytes Tff7b72?: Te6edf3ByteStringTb4b4b4.Te6edf3EMPTY

Te6edf3analyticsTb4b4b4.Te6edf3trackTb4b4b4(Ta5d6ff"Ta5d6ffdata_sendTa5d6ff"Tb4b4b4, Te6edf3DataPairTb4b4b4(Ta5d6ff"Ta5d6ffnum_bytesTa5d6ff"Tb4b4b4, Te6edf3bytesTb4b4b4.Te6edf3sizeTb4b4b4)Tb4b4b4, Te6edf3DataPairTb4b4b4(Ta5d6ff"Ta5d6fftypeTa5d6ff"Tb4b4b4, Te6edf3packetTb4b4b4.Te6edf3dataTypeTb4b4b4)Tb4b4b4)

T8b949e// Text messages report their own action from SendMessageUseCase, where the user acted; this path runs on

T8b949e// the send-queue worker and re-runs on retry, so counting them here would double up.

Tff7b72if Tb4b4b4(Te6edf3packetTb4b4b4.Te6edf3dataType Tff7b72!Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4.Te6edf3valueTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3actionName Tff7b72= Tff7b72if Tb4b4b4(Te6edf3packetTb4b4b4.Te6edf3dataType Tff7b72=Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3WAYPOINT_APPTb4b4b4.Te6edf3valueTb4b4b4) Ta5d6ff"Ta5d6ffwaypoint_sendTa5d6ff" Tff7b72else Ta5d6ff"Ta5d6ffdata_sendTa5d6ff"

Te6edf3analyticsTb4b4b4.Te6edf3trackActionTb4b4b4(Te6edf3actionNameTb4b4b4, Te6edf3mapOfTb4b4b4(Ta5d6ff"Ta5d6ffport_numTa5d6ff" Te6edf3to Te6edf3packetTb4b4b4.Te6edf3dataTypeTb4b4b4, Ta5d6ff"Ta5d6ffnum_bytesTa5d6ff" Te6edf3to Te6edf3bytesTb4b4b4.Te6edf3sizeTb4b4b4)Tb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsendReactionTb4b4b4(Te6edf3emojiTb4b4b4: Tffa657StringTb4b4b4, Te6edf3replyIdTb4b4b4: Tffa657IntTb4b4b4, Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3myNum Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4.Te6edf3value Tff7b72?: Tff7b72return

Tff7b72val Te6edf3parsedKey Tff7b72= Te6edf3ContactKeyTb4b4b4(Te6edf3contactKeyTb4b4b4)

Tff7b72val Te6edf3channel Tff7b72= Te6edf3parsedKeyTb4b4b4.Te6edf3channel

Tff7b72val Te6edf3destId Tff7b72= Te6edf3parsedKeyTb4b4b4.Te6edf3addressString

Tff7b72val Te6edf3dataPacket Tff7b72=

Te6edf3DataPacketTb4b4b4(

Te6edf3to Tff7b72= Te6edf3destIdTb4b4b4,

Te6edf3dataType Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4.Te6edf3valueTb4b4b4,

Te6edf3bytes Tff7b72= Te6edf3emojiTb4b4b4.Te6edf3encodeToByteArrayTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3toByteStringTb4b4b4(Tb4b4b4)Tb4b4b4,

Te6edf3channel Tff7b72= Te6edf3channelTb4b4b4,

Te6edf3replyId Tff7b72= Te6edf3replyIdTb4b4b4,

Te6edf3wantAck Tff7b72= Tff7b72trueTb4b4b4,

Te6edf3emoji Tff7b72= Te6edf3EMOJI_INDICATORTb4b4b4,

Tb4b4b4)

Tb4b4b4.Te6edf3apply Tb4b4b4{ Te6edf3from Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3getMyIdTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3takeIf Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3isNotEmptyTb4b4b4(Tb4b4b4) Tb4b4b4} Tff7b72?: Te6edf3NodeAddressTb4b4b4.Te6edf3ID_LOCAL Tb4b4b4}

Te6edf3commandSenderTb4b4b4.Te6edf3sendDataTb4b4b4(Te6edf3dataPacketTb4b4b4)

Te6edf3analyticsTb4b4b4.Te6edf3trackActionTb4b4b4(Ta5d6ff"Ta5d6ffreaction_sendTa5d6ff"Tb4b4b4)

Tff7b72val Te6edf3user Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNumTff7b72[Te6edf3myNumTff7b72]Tff7b72?.Te6edf3user Tff7b72?: Te6edf3UserTb4b4b4(Te6edf3id Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3getMyIdTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3packetRepositoryTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3insertReactionTb4b4b4(

Te6edf3ReactionTb4b4b4(

Te6edf3replyId Tff7b72= Te6edf3replyIdTb4b4b4,

Te6edf3user Tff7b72= Te6edf3userTb4b4b4,

Te6edf3emoji Tff7b72= Te6edf3emojiTb4b4b4,

Te6edf3timestamp Tff7b72= Te6edf3nowMillisTb4b4b4,

Te6edf3snr Tff7b72= T79c0ff0fTb4b4b4,

T8b949e// Our own reaction was never received over the air, so it has no rssi reading.

Te6edf3rssi Tff7b72= Tff7b72nullTb4b4b4,

Te6edf3hopsAway Tff7b72= T79c0ff0Tb4b4b4,

Te6edf3packetId Tff7b72= Te6edf3dataPacketTb4b4b4.Te6edf3idTb4b4b4,

Te6edf3status Tff7b72= Te6edf3dataPacketTb4b4b4.Te6edf3status Tff7b72?: Te6edf3MessageStatusTb4b4b4.Te6edf3QUEUEDTb4b4b4,

Te6edf3to Tff7b72= Te6edf3destIdTb4b4b4,

Te6edf3channel Tff7b72= Te6edf3channelTb4b4b4,

Tb4b4b4)Tb4b4b4,

Te6edf3myNumTb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsendSharedContactTb4b4b4(Te6edf3nodeNumTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Tffa657Boolean Tb4b4b4{

Tff7b72val Te6edf3myNum Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4.Te6edf3value Tff7b72?: Tff7b72return Tff7b72false

Tff7b72val Te6edf3nodeDef Tff7b72= Te6edf3nodeRepositoryTb4b4b4.Te6edf3getNodeTb4b4b4(Te6edf3NodeAddressTb4b4b4.Te6edf3numToDefaultIdTb4b4b4(Te6edf3nodeNumTb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3contact Tff7b72=

Te6edf3SharedContactTb4b4b4(Te6edf3node_num Tff7b72= Te6edf3nodeDefTb4b4b4.Te6edf3numTb4b4b4, Te6edf3user Tff7b72= Te6edf3nodeDefTb4b4b4.Te6edf3userTb4b4b4, Te6edf3manually_verified Tff7b72= Te6edf3nodeDefTb4b4b4.Te6edf3manuallyVerifiedTb4b4b4)

Tff7b72return Te6edf3safeCatching Tb4b4b4{ Te6edf3commandSenderTb4b4b4.Te6edf3sendAdminAwaitTb4b4b4(Te6edf3myNumTb4b4b4) Tb4b4b4{ Te6edf3AdminMessageTb4b4b4(Te6edf3add_contact Tff7b72= Te6edf3contactTb4b4b4) Tb4b4b4} Tb4b4b4}

Tb4b4b4.Te6edf3getOrDefaultTb4b4b4(Tff7b72falseTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffimportContactTb4b4b4(Te6edf3contactTb4b4b4: Te6edf3SharedContactTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3myNum Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4.Te6edf3value Tff7b72?: Tff7b72return

Tff7b72val Te6edf3user Tff7b72= Te6edf3contactTb4b4b4.Te6edf3user

Tff7b72if Tb4b4b4(Te6edf3contactTb4b4b4.Te6edf3node_num Tff7b72=Tff7b72= T79c0ff0 Tff7b72|Tff7b72| Te6edf3user Tff7b72=Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3w Tb4b4b4{ Ta5d6ff"Ta5d6ffimportContact rejected: missing node_num or user (node_num=Tffd700${Te6edf3contactTb4b4b4.Te6edf3node_numTffd700}Ta5d6ff)Ta5d6ff" Tb4b4b4}

Tff7b72return

Tb4b4b4}

T8b949e// Cross-platform policy: honor the verification state encoded by the sharer as-is

T8b949e// (see meshtastic/design standards/audits/nfc-alignment-audit.md).

Te6edf3commandSenderTb4b4b4.Te6edf3sendAdminTb4b4b4(Te6edf3myNumTb4b4b4) Tb4b4b4{ Te6edf3AdminMessageTb4b4b4(Te6edf3add_contact Tff7b72= Te6edf3contactTb4b4b4) Tb4b4b4}

Te6edf3nodeManagerTb4b4b4.Te6edf3handleReceivedUserTb4b4b4(Te6edf3contactTb4b4b4.Te6edf3node_numTb4b4b4, Te6edf3userTb4b4b4, Te6edf3manuallyVerified Tff7b72= Te6edf3contactTb4b4b4.Te6edf3manually_verifiedTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72companion Tff7b72object Tb4b4b4{

Tff7b72private Tff7b72const Tff7b72val Te6edf3EMOJI_INDICATOR Tff7b72= T79c0ff1

Tb4b4b4}

Tb4b4b4}